package com.BlockingQueue;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

/**
 * @author Zhang Guangyong
 * @desacription
 * @date 2019年08月20日 9:37
 */
public class BlockingQueueTest {

    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(2);

        blockingQueue.put("ggg");
        blockingQueue.put("ggg");
        blockingQueue.put("ggg");


    }
}
